package chapter4.read

import org.apache.spark.{SparkConf, SparkContext}

object Chapter4_3_1 {
  def main(args: Array[String]): Unit = {

    val conf = new SparkConf()
      .setAppName(this.getClass.getName)
      .setMaster("local")

    val sc = new SparkContext(conf)

    val inputTextFile = sc.textFile("P:\\Project\\Idea\\bigdata\\spark\\src\\main\\resources\\data\\chapter4_3_1.txt")

    println(inputTextFile.collect.mkString(","))

    sc.stop()
  }
}
